

In [2]:

    
import pymongo
from pymongo import InsertOne, DeleteMany, ReplaceOne, UpdateOne
from pymongo.errors import BulkWriteError
client = pymongo.MongoClient('101.132.182.124:27017')
db = client.tweet



In [3]:

    
import pandas as pd



In [4]:

    
from datetime import datetime

records = [] for i in db.test.find({'tweet.date':{'$lt':datetime.strptime('2017-10-03 00:00:00','%Y-%m-%d %H:%M:%S')}},{'tweet.text':1,'tweet.date':1}): records.append((i['_id'],i['tweet']['date'],i['tweet']['text']))

data = pd.DataFrame.from_records(records,columns=['id','date','text'],index=['id']) ids = data.index.tolist() test_ids = pd.DataFrame(ids) test_ids.to_csv('test_ids.csv',header=False,index=False)

positive



In [5]:

    
records = []
for i in db.test.find({'class.1':{'$gte':0.9},'tweet.date':{'$lt':datetime.strptime('2017-10-03 00:00:00','%Y-%m-%d %H:%M:%S')}},{'tweet.text':1,'tweet.date':1}):
    records.append((i['_id'],i['tweet']['date'],i['tweet']['text']))



In [6]:

    
data = pd.DataFrame.from_records(records,columns=['id','date','text'],index=['id'])
ids = data.index.tolist()
test_ids = pd.DataFrame(ids)
test_ids.to_csv('test_ids_pos.csv',header=False,index=False)



In [ ]:



In [ ]: